java读取sql文件并执行

2023-07-31 19:50| 来源: 网络整理| 查看: 265

在Java中读取SQL文件并执行可以通过以下步骤实现：

1.读取SQL文件：使用Java的FileReader或BufferedReader读取SQL文件内容。

2.连接数据库：使用Java的DriverManager类进行数据库连接。

3.创建Statement对象：使用Connection对象的createStatement()方法创建一个Statement对象。

4.执行SQL语句：使用Statement对象的executeUpdate()方法执行SQL语句。

代码示例如下：

import java.io.BufferedReader; import java.io.FileReader; import java.sql.Connection; import java.sql.DriverManager; import java.sql.Statement; public class SQLFileExecutor { public static void main(String[] args) { Connection conn = null; Statement stmt = null; try { // 注册JDBC驱动 Class.forName("com.mysql.jdbc.Driver"); // 打开连接 System.out.println("连接数据库..."); conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/dbname", "username", "password"); // 执行SQL文件 System.out.println("读取SQL文件并执行..."); stmt = conn.createStatement(); BufferedReader br = new BufferedReader(new FileReader("sqlFile.sql")); String line; while ((line = br.readLine()) != null) { line = line.trim(); if (!line.isEmpty() && !line.startsWith("--")) { stmt.executeUpdate(line); } } // 完成后关闭 br.close(); stmt.close(); conn.close(); } catch (Exception e) { e.printStackTrace(); } finally { try { if (stmt != null) { stmt.close(); } } catch (Exception e) { e.printStackTrace(); } try { if (conn != null) { conn.close(); } } catch (Exception e) { e.printStackTrace(); } } System.out.println("执行完毕!"); } }

希望这能帮助你。

【本文地址】

公司简介

联系我们